package io.kiki.sba.registry.server.data_store.multi.cluster.dataserver.handler;


import io.kiki.sba.registry.server.data_store.multi.cluster.executor.MultiClusterExecutorManager;
import io.kiki.sba.registry.server.data_store.remoting.dataserver.handler.BaseSlotDiffPublisherRequestHandler;
import org.springframework.beans.factory.annotation.Autowired;

import java.util.concurrent.Executor;

public class MultiClusterSlotDiffPublisherRequestHandler extends BaseSlotDiffPublisherRequestHandler {

    @Autowired
    private MultiClusterExecutorManager multiClusterExecutorManager;

    public MultiClusterSlotDiffPublisherRequestHandler() {
        super();
    }


    @Override
    public Executor getExecutor() {
        return multiClusterExecutorManager.getRemoteSlotSyncProcessorExecutor();
    }
}
